package kafka

type KafkaConfig struct {
	RequiredAckType int16    // kafka producer 响应模式 NoResponse = 0 ,WaitForLocal = 1 ,WaitForAll = -1
	Endpoints       []string // 连接地址
	OffsetMode      int64    // // OffsetNewest -1;OffsetOldest -2
}
